/*
package com.summer.framework.stream.mq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

*/
/**
 * @auther: 杨杰
 * @date: 2019/5/9 17:44
 * @description:
 *//*

@Component
@EnableBinding(StreamClient.class)
@Slf4j
public class StreamReceiver {  //消息接受类

    @StreamListener(StreamClient.INPUT)
    public void receiver(String userName){
        System.out.println("接收到消息："+userName);
    }
}
*/
